d05dc1a9e94f702089e847e1d30fc4cff505d4b3,hazelcast/src/main/java/com/hazelcast/queue/tx/TransactionalQueueProxySupport.java,TransactionalQueueProxySupport,pollInternal,#number#,71
Before Change
Future<QueueItem> f = invocation.invoke();
QueueItem item = f.get();
if (item != null){
if(!itemIdSet.add(item.getItemId())){
throw new TransactionException("Duplicate itemId: " + item.getItemId());
}
tx.addTransactionLog(new QueueTransactionLog(item.getItemId(), name, partitionId, new TxnPollOperation(name, item.getItemId())));
After Change
Future<QueueItem> f = invocation.invoke();
QueueItem item = f.get();
if (item != null){
if (reservedOffer != null && item.getItemId() == reservedOffer.getItemId()){
offerIdQueue.poll();
tx.removeTransactionLog(reservedOffer.getItemId());
return reservedOffer.getData();